package com.example.rxbyhand;

/**
 * Author by lp,on 2021/8/16/016,16:52.
 * 事件发射器
 */
public interface Emitter<T> {
    void onNext(T t);

    void onComplete();

    void onError(Throwable throwable);
}
